b7bab9b62f8dc9c1566f8c22d20ae4e77db3bf3a,hangout-input-plugins/hangout-input-plugins-kafka/src/main/java/com/ctrip/ops/sysdev/inputs/Kafka.java,Kafka,prepare,#,102

Before Change



        HashMap<String, String> consumerSettings = (HashMap<String, String>) this.config
                .get("consumer_settings");
        Iterator<Entry<String, String>> consumerSetting = consumerSettings
                .entrySet().iterator();

        while (consumerSetting.hasNext()) {
            Map.Entry<String, String> entry = consumerSetting.next();
            String k = entry.getKey();
            String v = entry.getValue();
            props.put(k, v);
        }
        consumer = kafka.consumer.Consumer
                .createJavaConsumerConnector(new ConsumerConfig(props));

After Change



        Properties props = new Properties();
        HashMap<String, String> consumerSettings = (HashMap<String, String>) this.config.get("consumer_settings");
        consumerSettings.entrySet().stream().forEach(entry -> props.put(entry.getKey(), entry.getValue()));
        consumer = kafka.consumer.Consumer.createJavaConsumerConnector(new ConsumerConfig(props));
        createProcessors();
    }